package org.ngbx.demo.flink.kafka.connector;

import lombok.Data;

@Data
public class KafkaMessage {
    private String key;

    private Integer value;

    @Override
    public String toString() {
        return "KafkaMessage{" +
                "key='" + key + '\'' +
                ", value='" + value + '\'' +
                '}';
    }
}
